package com.clj.rocketmq_example.service.impl;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.baomidou.mybatisplus.mapper.Wrapper;
import com.baomidou.mybatisplus.service.impl.ServiceImpl;
import com.clj.rocketmq_example.dal.entity.MessageEntity;
import com.clj.rocketmq_example.dal.mapper.MessageMapper;
import com.clj.rocketmq_example.service.MessageService;
@Service
public class MessageServiceImpl extends ServiceImpl<MessageMapper, MessageEntity> implements MessageService{
	 @Autowired
	    private MessageMapper messageMapper;
		

		
	    @Override
	    public MessageEntity selectById(Long id){
	        return super.selectById(id);
	    }

	    @Override
	    public Boolean save(MessageEntity messageEntity) {
	        return super.insert(messageEntity);
	    }

	    @Override
	    public MessageEntity getByMsgId(String msgid) {
	        Wrapper<MessageEntity> wrapper = new EntityWrapper<>();
	        wrapper.where("msgid={0}",msgid);
	        return super.selectOne(wrapper);
	    }
}
